package com.atguigu.demo;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableResult;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

public class FlinkSQLLookupJoin {
    //1.创建流动态表
    //2.创建lookup表
    //3.进行lookup join
    public static void main(String[] args) {
        //0.环境准备
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);

        TableResult tableResult = tableEnv.executeSql("sql");//真正执行 行动算子 insert select
        Table table = tableEnv.sqlQuery("sql");//并不是真正执行 转换算子


        //1.创建流动态表
        //2.创建lookup表
        //3.进行lookup join
    }
}
